package com.moli.iov.protocol.codec;


/*
 * 文件名： KafkaValueEncoder.java
 * 
 * 创建日期： 2017年3月14日
 *
 * Copyright(C) 2017, by <a href="mailto:liws@xingyuanauto.com">liws</a>.
 *
 * 原始作者: liws
 *
 */



import java.util.Map;


import com.moli.iov.protocol.util.SerializeUtils;
import org.apache.kafka.common.serialization.Deserializer;

/**
 * 消息上报 kafka消息value解码器
 *
 * @author <a href="mailto:liws@xingyuanauto.com">liws</a>
 *
 * @version $Revision$
 *
 * @since 2017年3月14日
 */
public class KafkaDecoder implements Deserializer<Object>{

	@Override
	public void configure(Map<String, ?> configs, boolean isKey) {
		// TODO Auto-generated method stub
		
	}

	@Override
	public Object deserialize(String topic, byte[] data) {
		return SerializeUtils.deserialize(data);
	}

	@Override
	public void close() {
		// TODO Auto-generated method stub
		
	}

	
}
